// 导入mysql模块
const mysql = require('mysql')
    // 建立与MySQL的连接关系
const db = mysql.createPool({
        host: '127.0.0.1', //数据库的ip地址
        user: 'root', //数据库的账号
        password: 'lc610256', //登录的密码
        database: 'my_db_01' //要操作的数据库名称

    })
    // 测试mysql是否成功，不具有任何意义
    // db.query('SELECT 1', (err, results) => {
    //     // 如果没成功，看一下错误信息
    //     if (err) return console.log(err.message);
    //     // 只要能打印出[RowDataPackage{'1':1}]的结果，就证明数据连接正常
    //     console.log(results);
    // })
    // 查询数据库中的数据,如果执行的是select查询语句，得到的是一个数组
    // const str = 'select * from users'
    // db.query(str, (err, res) => {
    //         if (err) return console.log(err.message);
    //         console.log(res);
    //     })
    //     //插入数据
    //     // 要插入到users表中的数据对象
    // const user = { username: 'Spider-Man', passward: 'pcc321' }
    //     // 带执行的SQL语句，其中？代表占位符
    // const sqlStr = 'insert into users (username,passward) values(?,?)'
    //     // 使用数组的形式，依次为占位符?指定具体的值
    // db.query(sqlStr, [user.username, user.passward], (err, res) => {
    //     if (err) return console.log(err.message);
    //     // 只要res.affectedRow 的值为1 就表示插入成功
    //     if (res.affectedRow === 1) console.log('数据插入成功');
    // })
    // 使用简便方法进行插入数据
    // const user = { username: 'blackbao', passward: '101110' }
    //     // user对象的名字和数据库中的字段一一对应，使用set ？进行占位
    // const sqlStr = 'insert into users set ?'
    // db.query(sqlStr, user, (err, res) => {
    //     if (err) return console.log(err.message);
    //     if (res.affectedRow === 1) return console.log('数据插入成功');
    // })

// // 更新数据
// const user = { id: 8, username: 'Iron-Man', passward: 'stark666' }
// const sqlStr = 'update users set ? where id=? '
// db.query(sqlStr, [user, user.id], (err, res) => {
//     if (err) return console.log(err.message);
//     if (res.affectedRow === 1) { console.log('数据更新成功'); }
// })
// 删除数据、
const sqlStr = 'delete from users where id=?'
    // 当数据中有多个占位符时，必须使用数组来填充，如果只有一个占位符时，可以不需要数组
db.query(sqlStr, 10, (err, res) => {
    if (err) return console.log(err.message);
    if (res.affectedRow === 1) { console.log('数据更新成功'); }
})